// pages/bindUser/bindUser.js
var mqtt = require('../../utils/mqtt.js');
//一个全局变量...
var client = null;
//一个全局变量...
let socketOpen = false

Page({
  /**
   * 页面的初始数据
   */
  data: {
    cardUid: "",
  },

  /**
   * 生命周期函数--监听页面加载
   */
  onLoad: function (options) {
      this.connectMqtt1();
  },
  // 连接mqtt服务器
  connectMqtt1: function () {
    const options = {
      connectTimeout: 4000, // 超时时间
      clientId: 'wx_' + parseInt(Math.random() * 100 + 800, 10),
      port: 8083, //重点注意这个,坑了我很久,一定是8083不是1883也不是443
      // username: 'xxx',
      // password: 'xxx',
    }

    client = mqtt.connect('wx://8.136.195.245/mqtt', options)
    client.on('reconnect', (error) => {
      console.log('正在重连:', error)
    })

    client.on('error', (error) => {
      console.log('连接失败:', error)
    })

    let that = this;
    client.on('connect', (e) => {
      console.log('成功连接服务器')
      //订阅一个主题
      client.subscribe('bindUser/carduid', {
        qos: 0
      }, function (err) {
        if (!err) {
          console.log("订阅成功")
        }
      })
    })
    client.on('message', function (topic, message) {
      console.log('received msg:' + message.toString());
    })
    client.publish('bindUser/username', 'wechat id is xxxxx')
  },
  /**
   * 生命周期函数--监听页面初次渲染完成
   */
  onReady: function () {

  },

  /**
   * 生命周期函数--监听页面显示
   */
  onShow: function () {

  },

  /**
   * 生命周期函数--监听页面隐藏
   */
  onHide: function () {

  },

  /**
   * 生命周期函数--监听页面卸载
   */
  onUnload: function () {

  },

  /**
   * 页面相关事件处理函数--监听用户下拉动作
   */
  onPullDownRefresh: function () {

  },

  /**
   * 页面上拉触底事件的处理函数
   */
  onReachBottom: function () {

  },

  /**
   * 用户点击右上角分享
   */
  onShareAppMessage: function () {

  }
})